//引入mymql模块
const mysql=require("mysql");
const pool=mysql.createPool({
    host:"localhost",
    user:"root",
    password:"root",
    database:"txdaojucheng",
    port:3306
})

const exec=(sql,params)=>{
    //封装一个promiseduixan
    return new Promise((resolve,reject)=>{
        //从链接池获取链接对象
        pool.getConnection((err,conn)=>{
            if(err){
                console.log("数据库连接失败");
                reject(err)
            }

            //通过连接对象,执行sql语句,获取结果
            conn.query(sql,params,(err,result)=>{
                if(err){
                    console.log("执行sql语句失败");
                    reject(err)
                }
                resolve(result)
                //释放连接
                conn.release();
            })
        })
    })
}

module.exports={exec}